package com.jvyou.thread.d13waitandnotify;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @author 橘柚
 * @version 1.0-SNAPSHOT
 * @Date 2024/7/31 14:34
 * @Description
 */
public class Application {

    public static void main(String[] args) throws InterruptedException {
        // 创建一个阻塞队列
        ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(5);
        Consumer consumer = new Consumer(queue);
        consumer.start();
        Cook cook = new Cook(queue);
        cook.start();
    }
}
